// package com.example.service.impl;
// 
// import com.example.config.AiConfig;
// import com.example.service.AiService;
// import com.fasterxml.jackson.databind.ObjectMapper;
// import lombok.RequiredArgsConstructor;
// import okhttp3.*;
// import org.springframework.stereotype.Service;
// 
// import java.io.IOException;
// import java.util.HashMap;
// import java.util.Map;
// 
// @Service
// @RequiredArgsConstructor
// public class AlibabaAiService implements AiService {
//     private final AiConfig aiConfig;
//     private final ObjectMapper objectMapper;
//     private final OkHttpClient client = new OkHttpClient();
// 
//     @Override
//     public String generateResponse(String prompt) {
//         Map<String, Object> requestBody = new HashMap<>();
//         requestBody.put("model", "qwen-turbo");
//         requestBody.put("input", new HashMap<String, Object>() {{
//             put("messages", new Object[]{
//                 new HashMap<String, String>() {{
//                     put("role", "user");
//                     put("content", prompt);
//                 }}
//             });
//         }});
// 
//         Request request = new Request.Builder()
//             .url(aiConfig.getAlibaba().getApiUrl())
//             .addHeader("Authorization", "Bearer " + aiConfig.getAlibaba().getApiKey())
//             .addHeader("Content-Type", "application/json")
//             .post(RequestBody.create(
//                 MediaType.parse("application/json"),
//                 objectMapper.writeValueAsString(requestBody)
//             ))
//             .build();
// 
//         try (Response response = client.newCall(request).execute()) {
//             if (!response.isSuccessful()) {
//                 throw new RuntimeException("API调用失败: " + response.code());
//             }
//             String responseBody = response.body().string();
//             Map<String, Object> responseMap = objectMapper.readValue(responseBody, Map.class);
//             return (String) ((Map) responseMap.get("output")).get("text");
//         } catch (IOException e) {
//             throw new RuntimeException("生成响应时发生错误", e);
//         }
//     }
// } 